type google.golang.org/grpc.parser
11 uses
google.golang.org/grpc (current package)
rpc_util.go#L535: type parser struct {
rpc_util.go#L560: func (p *parser) recvMsg(maxReceiveMessageSize int) (pf payloadFormat, msg []byte, err error) {
rpc_util.go#L691: func recvAndDecompress(p *parser, s *transport.Stream, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) ([]byte, error) {
rpc_util.go#L757: func recv(p *parser, c baseCodec, s *transport.Stream, dc Decompressor, m interface{}, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) error {
server.go#L1299: d, err := recvAndDecompress(&parser{r: stream}, stream, dc, s.opts.maxReceiveMessageSize, payInfo, decomp)
server.go#L1504: p: &parser{r: stream},
stream.go#L493: a.p = &parser{r: s}
stream.go#L555: p *parser
stream.go#L1252: as.p = &parser{r: s}
stream.go#L1289: p *parser
stream.go#L1506: p *parser